package com.eric.rxjava3;


import io.reactivex.rxjava3.annotations.NonNull;
import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.core.Observer;
import io.reactivex.rxjava3.disposables.Disposable;

/**
 * @author chenw-i
 * @version 1.0.0
 * @ClassName Main.java
 * @Description TODO
 * @createTime 2020年11月25日 15:29:00
 */
public class Main {
    public static void main(String[] args) {
        Observable.fromArray("11","22","33","44").subscribe(new Observer<String>() {
            @Override
            public void onSubscribe(@NonNull Disposable d) {

            }

            @Override
            public void onNext(@NonNull String s) {
                System.out.println(s);
            }

            @Override
            public void onError(@NonNull Throwable e) {

            }

            @Override
            public void onComplete() {

            }
        });
    }
}
